from __future__ import absolute_import
from celery import shared_task

from django.conf import settings
from django.utils import timezone
from django_redis import get_redis_connection

import logging

logger = logging.getLogger(__name__)


# @shared_task
# def has_tasks_log(*args, **kwargs):
#     """加载任务对象"""
#     try:
#         r = AllinpayRobotQiniuLog.objects.get(id=kwargs.get("idx"))
#     except BaseException as err:
#         return None
#     else:
#         return r
